//package com.topisv.tms.utils.http;
//
//import java.util.Date;
//import java.util.List;
//import java.util.Map;
//import java.util.TreeMap;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
//import com.topisv.tms.api.EdbAPITool;
//import com.topisv.tms.entity.EdiGoodsSku;
//import com.topisv.tms.entity.edb.EdbTask;
//import com.topisv.tms.service.EdiGoodsSkuService;
//import com.topisv.tms.service.edb.EdbTaskService;
//import com.topisv.tms.utils.TimeUtil;
//
//import net.sf.json.JSONArray;
//import net.sf.json.JSONObject;
//
//@Component
//public class SynchroEdbPorductGet implements Runnable {
//
//	private static final Logger log = LoggerFactory.getLogger(SynchroEdbPorductGet.class);
//	
//	@Autowired
//	private EdbTaskService edbTaskService;
//	@Autowired
//	private EdiGoodsSkuService ediGoodsSkuService;
//	private Object o=new Object();
//	private volatile boolean flag=true;
//	@Override
//	public void run() {
//		synchronized (o) {
//			
//			List<EdbTask> edbTasks = edbTaskService.findByMethodAndStatus("edbProductBaseInfoGet", "1");
//			
//			for(EdbTask edbTask : edbTasks)
//			{
//				log.info("开始同步E店宝商品信息");
//				try {
//					doSyncProduct(edbTask,"1");
//				} catch (Exception e) {
//					// TODO Auto-generated catch block
//					log.error(e.getMessage());
//				}
//			}
//		}
//
//	}
//	public void doSyncProduct(EdbTask edbTask,String page_no)throws Exception {
//		String param = edbTask.getParam();
//		Map<String,String> paramMap = getParam(param);
//		Date startDate = edbTask.getStartTime();
//		Date endDate = edbTask.getEndTime();
//		paramMap.put("StartTime", TimeUtil.getNowDateStringDD(startDate));
//		paramMap.put("EndTime", TimeUtil.getNowDateStringDD(endDate));
//		paramMap.put("pagenum", page_no);
//		paramMap.put("pagesize", edbTask.getPagesize());
//		int pagenum = Integer.parseInt(page_no);
//		String result = EdbAPITool.edbInterface(edbTask, paramMap);
//		log.info("E店宝商品信息" + result);
//		JSONObject json = JSONObject.fromObject(result);
//		if(json.containsKey("Success"))
//		{
//			JSONObject Success = json.getJSONObject("Success");
//			JSONObject items = Success.getJSONObject("items");
//			int total_results = Success.getInt("total_results");
//			JSONArray  item = items.getJSONArray("item");
//			if(total_results>0)
//			{
//				for(int i=0; i<item.size(); i++)
//				{
//					EdiGoodsSku ediGoodsSku=EdbAPITool.parseEdiGoodsSku(item.get(i).toString());
//					ediGoodsSku.setCustomerCode(edbTask.getCustomerCode());
//					ediGoodsSkuService.save(ediGoodsSku);
//				}
//				pagenum++;
//				//edbTask.setPagenum(pagenum +"");
//				doSyncProduct(edbTask,pagenum +"");
//			}
//		}
//	}
//	public void setFlag(boolean flag) {
//		this.flag = flag;
//	}
//	public Map<String,String> getParam(String param)
//	{
//		TreeMap<String, String> map = new TreeMap<String, String>();
//		if("".equals(param) || param == null)
//		{
//			return map;
//		}
//		String[] entrys = param.split("::");
//		for(String entry : entrys)
//		{
//			String[] p = entry.split("#");
//			map.put(p[0], p[1]);
//		}
//		return map;
//	}
//
//}
